package com.maben.queue.queue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

/**
 * 消息队列管理类
 */
public class MessageQueue {
    // 阻塞队列实例
    private static final BlockingQueue<Object> queue = new ArrayBlockingQueue<>(5);

    // 获取队列实例
    public static BlockingQueue<Object> getInstance() {
        return queue;
    }

    // 私有构造方法，防止实例化
    private MessageQueue() {
    }
}
    